package com.pxene.dmp.task;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.beans.factory.annotation.Autowired;

public abstract class MapReduceTask implements Tasklet {
	@Autowired
	protected Configuration configuration;
	@Autowired
	protected FileSystem hadoopFs;
	@Override
	public abstract RepeatStatus execute(StepContribution contribution, ChunkContext context) throws Exception;
}
